5638805fd592bff273287d492cecbc6a70ad67e2,src/main/java/teetime/framework/A3PipeInstantiation.java,A3PipeInstantiation,instantiatePipe,#IPipe#,59

Before Change


		Thread sourceStageThread = pipe.getSourcePort().getOwningStage().getOwningThread();
		Thread targetStageThread = pipe.getTargetPort().getOwningStage().getOwningThread();

		if (targetStageThread == null || sourceStageThread == targetStageThread) { // NOPMD .equals() can't be used here
			// normal or reflexive pipe => intra
			new UnsynchedPipe<T>(pipe.getSourcePort(), pipe.getTargetPort());
			if (LOGGER.isDebugEnabled()) {
				LOGGER.debug("Connected (unsynch) " + pipe.getSourcePort() + " and " + pipe.getTargetPort());
			}
		} else {
			// inter
			if (pipe.capacity() == 0) {
				new UnboundedSynchedPipe<T>(pipe.getSourcePort(), pipe.getTargetPort());
				if (LOGGER.isDebugEnabled()) {
					LOGGER.debug("Connected (unbounded) " + pipe.getSourcePort() + " and " + pipe.getTargetPort());
				}
			} else {
				new BoundedSynchedPipe<T>(pipe.getSourcePort(), pipe.getTargetPort(), pipe.capacity());
				if (LOGGER.isDebugEnabled()) {
					LOGGER.debug("Connected (bounded) " + pipe.getSourcePort() + " and " + pipe.getTargetPort());
				}
			}

After Change


		AbstractStage sourceStage = pipe.getSourcePort().getOwningStage();
		AbstractStage targetStage = pipe.getTargetPort().getOwningStage();

		if (!targetStage.isActive() || sourceStage == targetStage) { // NOPMD .equals() can't be used here
			// normal or reflexive pipe => intra
			new UnsynchedPipe<T>(pipe.getSourcePort(), pipe.getTargetPort());
			LOGGER.debug("Connected (unsynch) {} and {}", pipe.getSourcePort(), pipe.getTargetPort());
		} else {
			// inter
			if (pipe.capacity() == 0) {
				new UnboundedSynchedPipe<T>(pipe.getSourcePort(), pipe.getTargetPort());
				LOGGER.debug("Connected (unbounded) {} and {}", pipe.getSourcePort(), pipe.getTargetPort());
			} else {
				new BoundedSynchedPipe<T>(pipe.getSourcePort(), pipe.getTargetPort(), pipe.capacity());
				LOGGER.debug("Connected (bounded) {} and {}", pipe.getSourcePort(), pipe.getTargetPort());
			}
		}
	}